c552aaa6f1cd83582a61c7f1fd9e146da19c3c8a,spring-web-reactive/src/test/java/org/springframework/rx/io/ByteBufPublisherInputStreamTests.java,ByteBufPublisherInputStreamTests,readSingleByte,#,49
Before Change
@Test
public void readSingleByte() throws Exception {
ByteBuf abc = Unpooled.copiedBuffer(new byte[]{'a', 'b', 'c'});
ByteBuf def = Unpooled.copiedBuffer(new byte[]{'d', 'e', 'f'});
queue.putBuffer(abc);
queue.putBuffer(def);
queue.complete();
After Change
@Test
public void readSingleByte() throws Exception {
queue.putSignal(new byte[]{'a', 'b', 'c'});
queue.putSignal(new byte[]{'d', 'e', 'f'});
queue.complete();